package com.ml.plugins.rocketmq;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;

/**
 * 
 * @author Virgil
 * @Date 2020年8月24日
 * @Describe
 *           <p>
 *           定义管道
 *           </p>
 */
public interface MatchSink {

    
    //接收队列 订单变化
    String IN_ORDER_ALTER = "in-order-alter";
 
    //接收队列 新的成交
    String IN_NEW_TRADE = "in-new-trade";
    
    //接收队列 深度
    String IN_PUSH_DEPTH = "in-push-depth";
 
    @Input(MatchSink.IN_ORDER_ALTER)
    SubscribableChannel inOrderAlter();
    
    @Input(MatchSink.IN_NEW_TRADE)
    SubscribableChannel inNewTrade();
    
    @Input(MatchSink.IN_PUSH_DEPTH)
    SubscribableChannel pushDepth();
}
